type golang.org/x/net/http2.serverConn
85 uses
golang.org/x/net/http2 (current package)
server.go#L88: testHookGetServerConn func(*serverConn)
server.go#L90: testHookOnPanic func(sc *serverConn, panicVal interface{}) (rePanic bool)
server.go#L95: activeConns map[*serverConn]struct{}
server.go#L102: testNewConn func(*serverConn)
server.go#L105: func (s *serverInternalState) registerConn(sc *serverConn) {
server.go#L114: func (s *serverInternalState) unregisterConn(sc *serverConn) {
server.go#L163: activeConns: make(map[*serverConn]struct{}),
server.go#L260: func (s *Server) serveConn(c net.Conn, opts *ServeConnOpts, newf func(*serverConn)) {
server.go#L266: sc := &serverConn{
server.go#L407: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L415: type serverConn struct {
server.go#L487: func (sc *serverConn) writeSchedIgnoresRFC7540() bool {
server.go#L500: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L508: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L522: sc *serverConn
server.go#L546: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L547: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L548: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L549: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L553: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L580: func (sc *serverConn) setConnState(state http.ConnState) {
server.go#L586: func (sc *serverConn) vlogf(format string, args ...interface{}) {
server.go#L592: func (sc *serverConn) logf(format string, args ...interface{}) {
server.go#L640: func (sc *serverConn) condlogf(err error, format string, args ...interface{}) {
server.go#L659: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L695: func (sc *serverConn) readFrames() {
server.go#L727: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest, wd *writeData) {
server.go#L737: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L744: func (sc *serverConn) stopShutdownTimer() {
server.go#L751: func (sc *serverConn) notePanic() {
server.go#L766: func (sc *serverConn) serve(conf http2Config) {
server.go#L889: case func(*serverConn):
server.go#L915: func (sc *serverConn) handlePingTimer(lastFrameReadTime time.Time) {
server.go#L956: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L957: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L958: func (sc *serverConn) onReadIdleTimer() { sc.sendServeMsg(readIdleTimerMsg) }
server.go#L959: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L961: func (sc *serverConn) sendServeMsg(msg interface{}) {
server.go#L974: func (sc *serverConn) readPreface() error {
server.go#L1011: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1058: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1078: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1142: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1199: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1267: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1315: func (sc *serverConn) startGracefulShutdown() {
server.go#L1338: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1342: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1356: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1361: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1372: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1429: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1484: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1508: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1540: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1559: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1606: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1634: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1673: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1701: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1798: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L1864: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L1995: func (sc *serverConn) upgradeRequest(req *http.Request) {
server.go#L2049: func (sc *serverConn) checkPriority(streamID uint32, p PriorityParam) error {
server.go#L2060: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L2076: func (sc *serverConn) processPriorityUpdate(f *PriorityUpdateFrame) error {
server.go#L2089: func (sc *serverConn) newStream(id, pusherID uint32, state streamState, priority PriorityParam) *stream {
server.go#L2125: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2194: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp httpcommon.ServerRequestParam) (*responseWriter, *http.Request, error) {
server.go#L2230: func (sc *serverConn) newResponseWriter(st *stream, req *http.Request) *responseWriter {
server.go#L2251: func (sc *serverConn) scheduleHandler(streamID uint32, rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) error {
server.go#L2271: func (sc *serverConn) handlerDone() {
server.go#L2296: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2337: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2369: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2386: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2396: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2407: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2412: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2436: conn *serverConn
server.go#L2492: conn *serverConn
server.go#L2706: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L2732: w.rws.conn.sendServeMsg(func(sc *serverConn) {
server.go#L3047: func (sc *serverConn) startPush(msg *startPushRequest) {
server.go#L3191: func (sc *serverConn) countError(name string, err error) error {